package com.alibaba.otter.node.etl.load.loader.mq.rabbit.api;


import com.alibaba.otter.node.etl.load.loader.mq.rabbit.namespace.Namespace;

public interface ConnectionManager<K extends Namespace, V> {

    /**
     * 获取连接，连接返回前，请确保连接是有效的。
     * @param namespace
     * @return 连接
     */
    V getConnection(K namespace);
}
